package org.xi.maple.api

import org.apache.spark.sql.{Dataset, Row, SparkSession}

import scala.collection.mutable

trait MapleTransform[T <: TransformConfig] extends MaplePlugin[T] {
  def process(spark: SparkSession, argsMap: mutable.Map[String, String], ds: Dataset[Row]): Dataset[Row]
}

